package com.bls.executor.environment;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


public class MyMQ {

    public  Channel channel;

    public  MyMQ() throws Exception{
        System.out.println("mq start setting！");
        ConnectionFactory factory = new ConnectionFactory();
        factory.setUsername("lzh");
        factory.setPassword("fytest");
        factory.setHost("192.168.88.47");
        factory.setPort(5672);
        Connection connection = factory.newConnection();
        System.out.println("mqSuccess！");
        this.channel= connection.createChannel();
    }

}
